package com.gengzp.common.model.message.req;

import com.gengzp.mq.client.enums.MqMessageStatusEnum;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.Serializable;

/**
 * @ClassName PageMessageReq
 * @Description 分页查询消息请求实体
 * @Author gengzp
 * @Date 2025/9/30 9:49
 */
@Data
public class PageMessageReq implements Serializable {

    private static final Logger logger = LoggerFactory.getLogger(PageMessageReq.class);

    /**
     * 页码
     */
    private int pageNum = 1;

    /**
     * 每页数据条数
     */
    private int pageSize = 10;

    /**
     * 主题 topic
     */
    @NotBlank(message = "主题 topic 不能为空")
    private String topic;

    /**
     * 消息id
     */
    private String messageId;

    /**
     * 消息消费状态
     * {@link MqMessageStatusEnum}
     */
    @NotNull(message = "消息消费状态不能为空")
    private Integer status;

}
